/*package com.sxbbc.common.basics.service.activitymq;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.jms.listener.SessionAwareMessageListener;

import com.alibaba.fastjson.JSONObject;
import com.sxbbc.common.basics.exceptions.ThrowJsonException;

import common.Logger;
*//**
 * 支付回调通知处理
 * @author arno
 *
 *//*
public class QueueReceivedService implements SessionAwareMessageListener<Message>{
	private static Logger logger =Logger.getLogger(QueueReceivedService.class);
	@Override
	public void onMessage(Message message, Session session) throws JMSException {
	    TextMessage tm = (TextMessage)(message);
		JSONObject json=JSONObject.parseObject(tm.getText());
        try {
        	    String paycode=json.getString("paycode");
        	    String transcode=json.getString("transcode");
        		logger.info("支付回调通知paycode"+paycode+"交易单号"+transcode);
//           RestResponse result= handlePayService.handlePayCallback(paycode,transcode, "");
        		//处理回调业务逻辑
//             if(!result.isStatus()) {
//	            	//如果处理回调失败重新发送通知
//	            	 throw new ThrowJsonException(result.getDesc());
//             }
             // 收到消息之后进行确认      
     		// 只要被确认后  就会出队，接受失败没有确认成功，会在原队列里面
        		message.acknowledge();
        } catch (Exception e) {
        		logger.info("处理回调异常重新发送通知"+e.getMessage());
        		// 此不可省略 重发信息使用
            session.recover();
        }
	}

	
}
*/